package com.dky.satell.config;

import com.aliyun.openservices.ons.api.PropertyKeyConst;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

import java.util.Properties;

/**
 * @ClassName MqConfig
 * @Description
 * @Author superz
 * @Date 2021/4/27 15:01
 * @Version 1.0
 **/
@Data
@Configuration
@ConfigurationProperties(prefix = "rocketmq")
public class RocketMQConfig {

    private String accessKey;
    private String secretKey;
    private String nameSrvAddr;

    private String groupId;
    private String tag;

    public Properties getMqPropertie() {
        Properties properties = new Properties();
        // AccessKey ID阿里云身份验证，在阿里云服务器管理控制台创建。
        properties.setProperty(PropertyKeyConst.AccessKey, this.accessKey);
        // AccessKey Secret阿里云身份验证，在阿里云服务器管理控制台创建。
        properties.setProperty(PropertyKeyConst.SecretKey, this.secretKey);
        // 设置TCP协议接入点，进入控制台的实例详情页面的TCP协议客户端接入点区域查看。
        properties.setProperty(PropertyKeyConst.NAMESRV_ADDR, this.nameSrvAddr);
        return properties;
    }
}
